Micron Document
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| SparkN0de-git | SparkN0de |
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Node / ReticulumProjects / MeshChatX.git / commits / 4f6348f


Commit 4f6348fc69e7e61f7e73da67753eafae60cd1897

󰉖 Browse tree at this commit

Parents : 91e6842
Author : Ivan <ivan@quad4.io>
Signature : Signature validation error
Date : 2026-04-13T18:30:07-05:00

feat(rncp_handler): add tests for listener status and destination management, ensuring proper teardown and idempotent setup

Changes

1 files changed, 63 insertions(+), 0 deletions(-)

M tests/backend/test_rncp_handler_extended.py +63

Diff

diff --git a/tests/backend/test_rncp_handler_extended.py b/tests/backend/test_rncp_handler_extended.py
index f0a59bb7..b6c01d6c 100644
--- a/tests/backend/test_rncp_handler_extended.py
+++ b/tests/backend/test_rncp_handler_extended.py
@@ -83,3 +83,66 @@ def test_receive_resource_started(rncp_handler):
rncp_handler._receive_resource_started(mock_resource)
assert b"res_hash".hex() in rncp_handler.active_transfers
assert rncp_handler.active_transfers[b"res_hash".hex()]["status"] == "receiving"
+
+
+def test_get_listener_status_not_listening(rncp_handler):
+ s = rncp_handler.get_listener_status()
+ assert s["listening"] is False
+ assert s["destination_hash"] is None
+ assert s["allowed_hashes"] == []
+
+
+@patch("meshchatx.src.backend.rncp_handler.RNS.Transport")
+@patch("meshchatx.src.backend.rncp_handler.RNS.Identity")
+@patch("meshchatx.src.backend.rncp_handler.RNS.Destination")
+@patch("meshchatx.src.backend.rncp_handler.RNS.Reticulum")
+def test_teardown_receive_destination_deregisters(
+ mock_rns_reticulum,
+ mock_dest_class,
+ mock_identity_class,
+ mock_transport,
+ rncp_handler,
+):
+ mock_rns_reticulum.identitypath = "/tmp/rns/identities"
+ mock_id_obj = MagicMock()
+ mock_identity_class.from_file.return_value = mock_id_obj
+ mock_dest_obj = MagicMock()
+ mock_dest_obj.hash = b"\x01" * 16
+ mock_dest_class.return_value = mock_dest_obj
+
+ with patch("os.path.isfile", return_value=True):
+ rncp_handler.setup_receive_destination(allowed_hashes=["ab" * 16])
+
+ rncp_handler.teardown_receive_destination()
+
+ mock_transport.deregister_destination.assert_called_once_with(mock_dest_obj)
+ assert rncp_handler.receive_destination is None
+
+
+@patch("meshchatx.src.backend.rncp_handler.RNS.Transport")
+@patch("meshchatx.src.backend.rncp_handler.RNS.Identity")
+@patch("meshchatx.src.backend.rncp_handler.RNS.Destination")
+@patch("meshchatx.src.backend.rncp_handler.RNS.Reticulum")
+def test_setup_receive_destination_idempotent_restarts_listener(
+ mock_rns_reticulum,
+ mock_dest_class,
+ mock_identity_class,
+ mock_transport,
+ rncp_handler,
+):
+ mock_rns_reticulum.identitypath = "/tmp/rns/identities"
+ mock_id_obj = MagicMock()
+ mock_identity_class.from_file.return_value = mock_id_obj
+ first_dest = MagicMock()
+ first_dest.hash = b"\x02" * 16
+ second_dest = MagicMock()
+ second_dest.hash = b"\x03" * 16
+ mock_dest_class.side_effect = [first_dest, second_dest]
+
+ with patch("os.path.isfile", return_value=True):
+ rncp_handler.setup_receive_destination(allowed_hashes=["cd" * 16])
+ rncp_handler.setup_receive_destination(allowed_hashes=["ef" * 16])
+
+ assert mock_transport.deregister_destination.call_count == 1
+ assert mock_transport.deregister_destination.call_args[0][0] is first_dest
+ assert rncp_handler.receive_destination is second_dest


──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────